package com.practice.concurrency.signal;


public class Main {

	public static void main(String[] args) {
		
		Pipeline pipeline = new Pipeline();
		pipeline.setupCustomer();
		
		try {
			Thread.sleep(3000);
		} catch (InterruptedException ex) {
			ex.printStackTrace();
		}
		
		pipeline.setupProducer();
	}
}
